/**
 * Created by ztt on 2018/12/15.
 */
import { Observable,from, Scheduler} from "rxjs";
/**todo:调度器）
 * 调度器控制着，何时启动subscription和何时发送通知
 * 它有三部分组成
 *  1、调度器是一种数据结构，它知道如何根据优先级各其它标准来存储任务或将任务进行排序
 *  2、调度器是执行上下文。它表示何时何地执行任务
 *  3、调度器有一个虚拟时钟。调度器通过它的getter各now方法，提供了“时间的概念
 **/
var observable:Observable<any> =Observable.create(function (observer:any) {
    observer.next(1);
    observer.next(2);
    observer.next(3);
    observer.complete();
});

console.log('just before subscribe');
observable.subscribe({
    next: (x:any) => console.log('got value ' + x),
    error: (err:any) => console.error('something wrong occurred: ' + err),
    complete: () => console.log('done'),
});
console.log('just after subscribe');